package com.bfxy.disruptor.common.consume;

import com.bfxy.disruptor.common.balance.Sequence;
//单消费者使用BatchEventProcessor类，多消费者模式使用WorkProcessor。
//单消费者模式是有多少handler就启多少线程，
//多消费者模式不是，就是因为使用的是WorkProcessor。
//消费者与ringbuffer的桥梁
public interface EventConsumer extends Runnable
{
    Sequence getSequence();//消费者消费的是Sequence序列

    void halt();

    boolean isRunning();
}
